package com.yitiao.broker;

import com.yitiao.Message;
import com.yitiao.MessageProducer;
import com.yitiao.SendCallback;
import com.yitiao.exception.MessageRunTimeException;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.List;

@Component
public class ProducerClient implements MessageProducer {
    @Resource
    private RabbitBroker rabbitBroker;

    @Override
    public void send(Message message, SendCallback sendCallback) throws MessageRunTimeException {
        String messageType = message.getMessageType();
//        rabbitBroker.confirmSend();
    }

    @Override
    public void send(Message message) throws MessageRunTimeException {

    }

    @Override
    public void send(List<Message> messages) throws MessageRunTimeException {

    }
}
